

package com.hazelcast.jet.impl.connector;

import com.hazelcast.function.SupplierEx;
import com.hazelcast.test.annotation.ParallelJVMTest;
import com.hazelcast.test.annotation.QuickTest;
import jakarta.jms.ConnectionFactory;
import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.apache.activemq.artemis.junit.EmbeddedActiveMQResource;
import org.junit.ClassRule;
import org.junit.Ignore;
import org.junit.experimental.categories.Category;

@Ignore // ignored due to https://issues.apache.org/jira/browse/ARTEMIS-2735
@Category({QuickTest.class, ParallelJVMTest.class})
public class JmsSourceIntegrationTest_ActiveMqArtemis extends JmsSourceIntegrationTestBase {

    @ClassRule
    public static EmbeddedActiveMQResource broker = new EmbeddedActiveMQResource();

    private static final SupplierEx<ConnectionFactory> FACTORY_SUPPLIER = () -> new ActiveMQConnectionFactory(broker.getVmURL());

    @Override
    protected SupplierEx<ConnectionFactory> getConnectionFactory() {
        return FACTORY_SUPPLIER;
    }
}
